package com.yangye.niodemo.rpc.transport;

import com.yangye.niodemo.rpc.protocol.PackageMsg;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * @author yangye
 * @date 2020/12/29
 */
public class ClientHandler extends ChannelInboundHandlerAdapter {

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		PackageMsg packageMsg = (PackageMsg) msg;
		// 返回
		ResponseCallback.run(packageMsg);
	}
}
